Another way to create a Channel is via Channel().

This looks like a constructor, but Channel is an interface, not a class. In reality, Channel() is simply a top-level factory function, sharing a name with the interface.

It takes a parameter indicating how send() should work:

  • 0 indicates that send() should block until the consumer of the channel is able to receive the object

  • Channel.UNLIMITED means that send() always returns immediately, and the channel will buffer objects up until the limit of available memory

  • Channel.CONFLATED means that send() always returns immediately, but only the last object sent is buffered — all previous objects are lost

  • Any other positive Int value (but less than Channel.UNLIMITED) means that the channel will buffer that number of elements, and send() might block until a consumer can receive objects if that buffer is full (Channel.BUFFERED uses a default capacity of 64 elements)

You can learn more about this in:
Tags:
A Conflated Channel A Fixed-Buffer Channel A Simple Channel A Zero-Buffer Channel BroadcastChannel Channel and receive() Channels and Fan-out Hot Channels Via offer() The Channel() Function toList() for Channel
A Conflated Channel A Fixed-Buffer Channel A Parallel Coroutine Sample A Sequential Coroutine Sample A Simple Channel A Simple Coroutine Sample A Simple Flow A Simple SharedFlow A Simple StateFlow A Zero-Buffer Channel async() BroadcastChannel cancelAndJoin() Canceling a Job Canceling a Parent Cancels Its Children Canceling and Cooperation catch() Channel and receive() Channels and Fan-out combine() Operator Contexts and Jobs Cooperation by Checking isActive Cooperation by Yielding debounce() Operator distinctUntilChanged() Operator distinctUntilChangedBy() Operator drop() Operator dropWhile() Operator filter() Operator filterIsInstance() Operator filterNot() Operator filterNotNull() Operator first() and Flow flattenConcat() Operator flattenMerge() Operator Flow Actions Flow onStart() flowOf() flowOn() Flows and Exceptions fold() Operator Hot Channels Via offer() invokeOnCompletion() Jobs and Parents Jobs Cancel When They Crash join() Lazy Coroutines map() Operator mapLatest() Operator mapNotNull() Operator Massively Parallel Coroutines MutableSharedFlow Replay Option Non-Cancellable Coroutines Parent Jobs Cancel When a Child Crashes promise() retry() retryWhen() runBlocking() sample() Operator scan() Operator single() and singleOrNull() Starting Lazy Coroutines StateFlow and Content Equality suspend Functions and Flows Suspending main() take() Operator takeWhile() Operator The Channel() Function TimeoutCancellationException Timeouts toList() and toSet() toList() for Channel withIndex() Operator withTimeoutOrNull() zip() Operator
Run Edit